#include <iostream>
#include <string>
#include "zmq.hpp"
#include "zmq_addon.hpp"

using namespace std;
int main()
{
    zmq::context_t zmq_context(1);                  //获取zmq上下文
    zmq::socket_t zmq_socket(zmq_context,ZMQ_SUB);  //创建ZMQ_PUB模式的socket

//    zmq_socket.connect("tcp://localhost:5556");     //通过一个socket创建一个对外连接

//    char topic[] = "333";
//    zmq_socket.set(zmq::sockopt::subscribe, zmq::const_buffer(topic, strlen(topic))); //设置过滤条件
//    zmq_socket.setsockopt(ZMQ_SUBSCRIBE, "", 0);
//    zmq_socket.connect("tcp://127.0.0.1:5556");     //通过一个socket创建一个对外连接

    zmq_socket.set(zmq::sockopt::subscribe, ""); //设置过滤条件
    zmq_socket.connect("tcp://127.0.0.1:5556");     //通过一个socket创建一个对外连接


    zmq::message_t msg;
    while(1)
    {
        zmq_socket.recv(msg, zmq::recv_flags::none);      //接收消息
        cout << msg.to_string() << endl;
    }

    return 0;
}
